/**
 * 服务端 API 代理 —— 将 /api/** 请求转发到 ThinkJS 后端
 *
 * 对齐 ai_uniapp_v2 H5 端的 manifest.json devServer.proxy 行为：
 *   /api/user/info → https://api.jiefuku.com/user/info
 *
 * 用途：
 *   1. 避免浏览器跨域
 *   2. 服务端转发自动携带 cookie，保持登录态
 *
 * 环境变量 API_BASE 可覆盖目标地址（生产环境指向 https://api.aionline.cc）
 */
export default defineEventHandler(async (event) => {
  const apiBase = process.env.API_BASE || 'http://192.168.31.168:16888'

  // 去掉 /api 前缀，得到真实后端路径
  let path = event.path.replace(/^\/api/, '') || '/'
  if (!path.startsWith('/')) path = '/' + path

  const method = event.method
  const url = apiBase + path

  const headers = {}

  // 转发用户 cookie（保持登录态）
  const cookie = event.headers.get('cookie')
  if (cookie) {
    headers.cookie = cookie
  }

  // 透传客户端的 Content-Type（multipart/form-data 上传需要）
  const contentType = event.headers.get('content-type')
  if (contentType) {
    headers['content-type'] = contentType
  }

  // 透传签名的 header（nonce / timestr / token）
  const clientNonce = event.headers.get('nonce')
  const clientTimestr = event.headers.get('timestr')
  const clientToken = event.headers.get('token')
  if (clientNonce) headers.nonce = clientNonce
  if (clientTimestr) headers.timestr = clientTimestr
  if (clientToken) headers.token = clientToken

  const fetchOptions = { method, headers }

  // GET: 查询参数
  const query = getQuery(event)
  const queryStr = new URLSearchParams(query).toString()
  const fullUrl = queryStr ? url + '?' + queryStr : url

  // POST: 请求体
  if (method === 'POST') {
    const body = await readBody(event)
    if (body && typeof body === 'object') {
      // 如果是 FormData 上传（multipart），直接透传原始 body
      if (contentType && contentType.includes('multipart/form-data')) {
        // multipart 请求的 body 需要特殊处理，直接用原始 buffer
        const rawBody = await readRawBody(event)
        if (rawBody) {
          fetchOptions.body = rawBody
          // 保留原始 boundary
          fetchOptions.headers = { ...fetchOptions.headers, 'content-type': contentType }
        }
      } else {
        fetchOptions.body = new URLSearchParams(body).toString()
      }
    }
  }

  try {
    return await $fetch(fullUrl, fetchOptions)
  } catch (error) {
    console.error('[Server Proxy Error]', url, error.message)
    return {
      code: 1000,
      data: null,
      msg: '服务器代理请求失败',
    }
  }
})